home *** CD-ROM | disk | FTP | other *** search
/ Windows Expert / Windows Expert.iso / windownt / queue.zip / QUEUE / QSRV.C < prev    next >
C/C++ Source or Header  |  1992-10-10  |  4KB  |  158 lines
  1. /************************************************************************\
  2. * The enclosed files, "the software," is provided by 
  3. * Microsoft Corporation "as is" without warranty of any kind. 
  4. * MICROSOFT DISCLAIMS ALL WARRANTIES, EITHER EXPRESS OR IMPLIED, 
  5. * INCLUDING BUT NOT LIMITED TO IMPLIED WARRANTIES OF MERCHANTABILITY 
  6. * AND FITNESS FOR A PARTICULAR PURPOSE.  You assume all risks of 
  7. * using the software.
  8. * 
  9. * The software is Copyright (c) 1992 Microsoft Corporation.
  10. * Original Author: John M. Hall, Microsoft SDE  9/1/92
  11. *
  12. * You are granted the right to freely distribute this software.
  13. * You are granted the right to make changes provided this comment block
  14. * is retained without modification and you acknowledge the changes.
  15. * 
  16. \************************************************************************/
  17. #define DEBUG
  18. #include <stdio.h>
  19. #include <assert.h>
  20. #include <windows.h>
  21. #include <string.h>
  22. #include <queue.h>
  23. #include <shrmem.h>
  24. #include <myopt.h>
  25.  
  26. #define QUEUE_NAME "\\queues\\test"
  27.  
  28. main(int argc, char *argv[])
  29. {
  30.     HQUEUE  hq;
  31.     DWORD   dwErr;
  32.     HANDLE  hEvent;
  33.     DWORD   dwProcess = 1;
  34.     Q_ELEMENT qe;
  35.     LPTSTR  lptstr;
  36.     HANDLE  hProcess = GetCurrentProcess();
  37.     HANDLE  hClient;
  38.     int     iType = QUE_FIFO;
  39.     BOOL    bWait = FALSE;
  40.     int     iFlag;
  41.     BOOL    bPeek = FALSE;
  42.     int     iElement = -1;
  43.  
  44.  
  45.     while (iFlag = my_getopt( argc, argv, "plfwP"))
  46.         {
  47.         switch(iFlag)
  48.             {
  49.             case 'P':
  50.                 bPeek = TRUE;
  51.                 bWait = TRUE;
  52.                 break;
  53.  
  54.             case 'p':
  55.                 iType = QUE_PRIORITY;
  56.                 break;
  57.             case 'l':
  58.                 iType = QUE_LIFO;
  59.                 break;
  60.             case 'f':
  61.                 iType = QUE_FIFO;
  62.                 break;
  63.             case 'w':
  64.                 bWait = TRUE;
  65.                 break;
  66.             default:
  67.                 printf( "Unidentified flag %c\n", (char) iFlag);
  68.                 break;
  69.             }
  70.         }
  71.  
  72.  
  73.     if (bWait)
  74.         hClient = CreateEvent( NULL, TRUE, FALSE, "ClientSaysGo");
  75.  
  76.     dwErr = CreateQueue( &hq, iType, QUEUE_NAME);
  77.  
  78.     if (dwErr != 0)
  79.         {
  80.         printf( "CreateQueue Failed\n");
  81.         return(-1);
  82.         }
  83.  
  84.     hEvent = GetQueueEventHandle(hq);
  85.  
  86.     if (hEvent == 0)
  87.         {
  88.         CloseQueue(hq);
  89.         printf( "GetQueueEventHandle Failed\n");
  90.         return(-1);
  91.         }
  92.     else
  93.         printf( "GetQueueEventHandle Succeeded\n");
  94.  
  95.  
  96.     if (bWait)
  97.         WaitForSingleObject(hClient, INFINITE);
  98.  
  99.     while (bPeek)
  100.         {
  101.         SetPriorityClass(hProcess, HIGH_PRIORITY_CLASS);
  102.         WaitForSingleObject(hEvent, INFINITE);
  103.  
  104.         if (PeekQueue(hq, &qe, &iElement, FALSE) != 0)
  105.             {
  106.             bPeek = FALSE;
  107.             printf( "End of Peek's\n");
  108.             continue;
  109.             }
  110.  
  111.         SetPriorityClass(hProcess, NORMAL_PRIORITY_CLASS);
  112.  
  113.         printf( "E %5d,  P %5d, W %5d, S %5d, ",
  114.             qe.dwEventCode, qe.dwPriority, qe.dwWriterId, qe.dwShrHandle);
  115.  
  116.         if (qe.dwShrHandle != 0)
  117.             {
  118.             lptstr = (LPTSTR) ShrLock(qe.dwShrHandle);
  119.             printf( "M:%30s.\n", lptstr);
  120.             ShrUnlock(qe.dwShrHandle);
  121.             }
  122.  
  123.         }
  124.  
  125.     while (dwProcess)
  126.         {
  127.         SetPriorityClass(hProcess, HIGH_PRIORITY_CLASS);
  128.         WaitForSingleObject(hEvent, INFINITE);
  129.  
  130.         dwErr = ReadQueue(hq, &qe, 0, FALSE);
  131.  
  132.         SetPriorityClass(hProcess, NORMAL_PRIORITY_CLASS);
  133.  
  134.         if (dwErr != 0)
  135.             {
  136.             printf( "ReadQueue failed\n");
  137.             }
  138.  
  139.  
  140.         dwProcess = qe.dwEventCode;
  141.  
  142.         printf( "E %5d,  P %5d, W %5d, S %5d, ",
  143.             qe.dwEventCode, qe.dwPriority, qe.dwWriterId, qe.dwShrHandle);
  144.  
  145.         if (qe.dwShrHandle != 0)
  146.             {
  147.             lptstr = (LPTSTR) ShrLock(qe.dwShrHandle);
  148.             printf( "M:%30s.\n", lptstr);
  149.             ShrUnlock(qe.dwShrHandle);
  150.             ShrFree(qe.dwShrHandle);
  151.             }
  152.         }
  153.     CloseQueue(hq);
  154.     printf( "Server exiting\n");
  155.  
  156.     return(0);
  157. }
  158.